package spring.module.disruptor.message;

import com.lmax.disruptor.EventHandler;

import lombok.extern.slf4j.Slf4j;

/**
 * 消费者
 * 
 * @author Lucky Yang

 */
@Slf4j
public class MessageConsumer implements EventHandler<MessageModel> {
    @Override
    public void onEvent(MessageModel event, long sequence, boolean endOfBatch) {
        log.info("{}-接收到消息: {}", this, event.getMessage());
        // 模拟业务处理
    }
}
